4f41e048acb731de7d8bc91c5aed3c3b8ed2c81f,cache-tests/src/test/java/org/jsr107/tck/integration/CacheWriterTest.java,CacheWriterTest,shouldWriteThroughUsingInvokeAll_setValue_UpdateEntry,#,407

Before Change



        assertEquals(NUMBER_OF_KEYS, cacheWriter.getWriteCount());
        assertEquals(0, cacheWriter.getDeleteCount());
        cache.invokeAll(keys, new Cache.EntryProcessor<Integer, String, Void>() {
            @Override
            public Void process(Cache.MutableEntry<Integer, String> entry, Object... arguments) {
                entry.setValue(VALUE_PREFIX_UPDATED + entry.getKey());

                return null;
            }
        });

        assertEquals(NUMBER_OF_KEYS * 2, cacheWriter.getWriteCount());
        assertEquals(0, cacheWriter.getDeleteCount());

After Change



        assertEquals(NUMBER_OF_KEYS, cacheWriter.getWriteCount());
        assertEquals(0, cacheWriter.getDeleteCount());
        cache.invokeAll(keys, new SetEntryWithComputedValueProcessor<Integer>(VALUE_PREFIX_UPDATED, ""));
        assertEquals(NUMBER_OF_KEYS * 2, cacheWriter.getWriteCount());
        assertEquals(0, cacheWriter.getDeleteCount());
        for (Integer key : keys) {